//package com.snow.campuslink.user.test;
//
//import com.alibaba.fastjson.JSON;
//import com.snow.campuslink.project.rabbitmq.MqMessage;
//import org.springframework.amqp.core.ExchangeTypes;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.*;
//import org.springframework.stereotype.Component;
//
///**
// * TODO
// *
// * @author Gaosl
// * @className ErrorReceiver
// * @date 2021/3/7 18:37
// */
//@Component
//@RabbitListener(
//        bindings=@QueueBinding(
//                value=@Queue(value="log.error",autoDelete="false"),
//                exchange=@Exchange(value="log.direct",type= ExchangeTypes.DIRECT),
//                key="log.error.routing.key"
//        )
//)
//    public class ErrorReceiver {
//    /**
//     * 消费消息的方法。采用消息队列监听机制
//     * @RabbitHandler - 代表当前方法是监听队列状态的方法，就是队列状态发生变化后，执行的消费消息的方法。
//     * 方法参数。就是处理的消息的数据载体类型。
//     */
//    @RabbitHandler
//    public void process(Object msg){
//        Message msg1 = (Message) msg;
//        String s = new String(msg1.getBody());
//        MqMessage mqMessage = JSON.parseObject(s, MqMessage.class);
//        System.out.println(mqMessage.getDatetime());
//        System.out.println(mqMessage.getFrom());
//        System.out.println(mqMessage.getData());
//        System.out.println(msg1.getMessageProperties());
//        System.out.println("Error..........receiver: "+msg1);
//
//
//    }
//}
